package com.xjscrm.server.biz.mq.consumer;

import com.uzai.mobile.collect.api.dto.MicaTransDto;
import com.uzai.trace.TraceGenerate;
import com.uzai.trace.boot.autoconfiguration.TraceProperties;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.beans.factory.annotation.Autowired;

/**
 * 服务器消息消费基类
 *
 * @author liuqi
 * @date 2024年03月05日 10:37
 */

public abstract class BaseTransMqConsumer implements RocketMQListener<MicaTransDto> {

    @Autowired
    private TraceProperties traceProperties;

    @Override
    @TraceGenerate //注入消息id标签
    public void onMessage(MicaTransDto micaTransDto) {
        this.doMessageHandle(micaTransDto);
    }

    public abstract void doMessageHandle(MicaTransDto micaTransDto);

}
